/*
Copyright 2017 Google Inc. All Rights Reserved.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS-IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

#include "seurat/base/bytestream.h"

#include <cstring>

#include "ion/base/logging.h"

namespace seurat {
namespace base {

void UncheckedArrayByteSink::Append(const char* data, size_t n) {
  if (data != dest_) {
    CHECK(!(dest_ <= data && data < (dest_ + n)));
    std::memcpy(dest_, data, n);
  }
  dest_ += n;
}

void ByteSource::CopyTo(ByteSink* sink, size_t n) {
  while (n > 0) {
    absl::string_view fragment = Peek();
    if (fragment.empty()) {
      LOG(ERROR) << "ByteSource::CopyTo() overran input.";
      break;
    }
    size_t fragment_size = std::min<size_t>(n, fragment.size());
    sink->Append(fragment.data(), fragment_size);
    Skip(fragment_size);
    n -= fragment_size;
  }
}

}  // namespace base
}  // namespace seurat
